package cn.doitedu.day05

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.3
 * @Created by HANGGE
 * @Description
 */
object A04_行动算子_Reduce_fold {
  def main(args: Array[String]): Unit = {

    val sc = SparkUtil.getSc

    val rdd = sc.parallelize(List(2,1,3,4,5) ,2)
    // 分区内的计算  和  分区间的计算一致
    val res = rdd.reduce(_ + _)
    // 默认值参与每个分区的计算  参与 分区间的计算
    val res2 = rdd.fold(10)(_ + _)
    println(res2)



  }

}
